package com.xry.test1.service.MQTTSubscriber;

import org.eclipse.paho.client.mqttv3.MqttMessage;

public interface MqttMessageHandler {
    void handleIncomingMessage(String topic, MqttMessage message);
}
